package com.wzh.project.redis.product;

import com.wzh.project.redis.utils.JedisUtils;

public class ProducerThread implements Runnable {
	private static String queueName="queue";//默认发送，监听的队列名
	private static String serverInfo="redis";//默认的服务器信息,该key对应一个配置文件
	@Override
	public void run() {
		
		try {
			JedisUtils.sendObj(serverInfo,queueName, "req", "corllerationId", null, null, false);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}
